package risk.control.project.config.mongo;

/**
 * 一个服务对应一个数据库
 */
//@Component("MongoDbHelper")
//public class MongoDbHelper implements AutoCloseable {

//    private static final Logger logger = LoggerFactory.getLogger(MongoDbHelper.class);
//
//    @Qualifier("MongoClient")
//    private final MongoClient mongoClient;
//
//    public MongoDbHelper(MongoClient mongoClient) {
//        this.mongoClient = mongoClient;
//    }
//
//    //获取用户集合
//    public MongoCollection<Document> getUserCollection() {
//        MongoDatabase riskDb = mongoClient.getDatabase("risk_db");
//        return riskDb.getCollection("user_collection");
//    }
//
//    //动态获取集合
//    public MongoCollection<Document> getDynamicCollection(String collectionName) {
//        MongoDatabase riskDb = mongoClient.getDatabase("risk_db");
//        return riskDb.getCollection(collectionName);
//    }
//
//    @PreDestroy
//    @Override
//    public void close() {
//        if (mongoClient != null) {
//            mongoClient.close();
//        }
//    }
//}
